package com.bootdo.acitvity.DDD.application.dubbo.dto;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface MQChannel {

    @Input("BATCH_STOCK_SYNC_INPUT")
    SubscribableChannel batchStockSyncInput();

    @Input("BATCH_STOCK_CHECK_INPUT")
    MessageChannel batchStockCheckInput();

}
